d5c500d94cd574fd5e55346e7cd46cb4f37cc6c4,hazelcast-client-legacy/src/test/java/com/hazelcast/client/map/ClientMapStoreTest.java,ClientMapStoreTest,mapSize_After_MapStore_OperationQueue_OverFlow_Test,#,114

Before Change


        final IMap map = client.getMap(MAP_NAME);


        final int max = getMaxCapacity(server) + 1;
        for (int i = 0; i < max; i++) {
            map.putAsync(i, i);
        }

        Thread.sleep(1000 * (delaySeconds + 1));

After Change


        HazelcastInstance client = hazelcastFactory.newHazelcastClient();
        IMap map = client.getMap(MAP_NAME);

        int maxCapacity = getMaxCapacity(server);
        List<Future> futures = new ArrayList<Future>(maxCapacity * 2);
        for (int i = 0; i < maxCapacity * 2; i++) {
            Future future = map.putAsync(i, i);
            futures.add(future);
        }

        int success = 0;
        for (Future future : futures) {
            try {
                future.get();
                success++;
            } catch (ReachedMaxSizeException e) {
                //ignore
            }